package com.lgj.rocketmq.message;

import lombok.Data;
import java.io.Serializable;
/**
 * @author: guangjie.liao
 * @Date: 2023/9/10 10:42
 * @Description: 消息类
 */
@Data
public class RocketMessage<T> implements Serializable {
    private String producer;
    private String topic;
    private T body;

    public RocketMessage(String topic, T body){
        this.body = body;
        this.topic = topic;
    }
}
